package com.example.xxljobtest.job;


import com.example.xxljobtest.entity.SyncData;
import com.example.xxljobtest.mapper.SyncDataMapper;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Date;

@Component
public class SyncDataJobHandler {

    @Autowired
    private SyncDataMapper syncDataMapper;

    @XxlJob("syncDataJobHandler")  // 任务Handler名称（需与调度中心配置一致）
    public void execute() {
        // 1. 模拟数据
        String content = "Synced by MPJ at " + new Date();

        // 2. 插入数据库
        SyncData data = new SyncData();
        data.setContent(content);
        data.setSyncTime(new Date());
        int rows = syncDataMapper.insert(data);

        // 3. 记录日志（可选）
        XxlJobHelper.log("插入数据成功，影响行数: {}", rows);

        // 4. 返回结果（XXL-JOB 2.3.0+ 版本支持 void 方法）
    }
}